// //引入mysql
// const mysql = require('mysql')
// //创建连接池
// const pool = mysql.createPool({
//     user: 'root',
//     connectionLimit: 10,
//     password: '123456',
//     database: 'dome',
//     host: '127.0.0.1',
// })
// module.exports = function (req, res) {
//     return new Promise((resolve, reject) => {
//         pool.getConnection((err, connection) => {
//             if (err) {
//                 reject(err)
//             } else {
//                 connection.query(sql, parmas, (err, result) => {
//                     connection.release()
//                     if (err) {
//                         reject(err)
//                     } else (
//                         resolve(result)
//                     )
//                 })
//             }
//         })
//     })
// }

// //引入
// const mysql=require('mysql')
// //创建连接池
// const pool=mysql.createPool({
//     user:'root',
//     password:'123456',
//     database:'demo',
//     host:'127.0.0.1',
//     connectionLimit:10,
// })
// module.default=function(req,res){
//     return new prommise((resolve,reject)=>{
//         pool.getConnection((err,connection)=>{
//             if(err){
//                 resolve(err)
//             }else{
//              connection.query(sql,parmas,(err,result)=>{
//                 connection.release()
//                 if(err){
//                    reject(err)
//                 }else{
//                  resolve(reject)
//                 }
//              })
//             }
//         })
//     })
// }

//引入mysql
const mysql = require('mysql')
//建立连接池
const pool = mysql.createPool({
    user: 'root',
    connectionLimit: 10,
    host: '127.0.0.1',
    password: '123456',
    database: 'demo',
    timezone: 'utc'//mysql默认的时区是utc 连接是本地时区，相差8小时
})
module.exports = function (sql, parmas) {
    //返回一个异步请求
    return new Promise((resolve, reject) => {
        //建立连接 两种结果
        pool.getConnection((err, connection) => {
            if (err) {
                reject(err)
            } else {
                //连接成功 发送请求
                connection.query(sql, parmas, (err, result) => {
                    //释放请求
                    connection.release()
                    if (err) {
                        reject(err)
                    } else {
                        resolve(result)
                    }
                })
            }
        })
    })
}
